package cn.itcast.dmp.tags
import org.apache.commons.lang3.StringUtils
import org.apache.spark.sql.Row
/**
  * 年龄标签(AgeTag)生成
  */
object Tags4AgeMaker extends TagsMaker {
  override def make(row: Row, dic: Map[String, String]): Map[String, Double] = {
    // 依据字段获取值
    val ageValue = row.getAs[String]("age")
    // 判断是否不为空，是的话生成标签
    if(StringUtils.isNotBlank(ageValue)){
      Map(s"$AG@age" -> 1.0)
    }else{
      Map[String, Double]()
    }

  }
}
